9fa9a7430595f5f84d1617862efc5867192f34f6,cdap-app-templates/cdap-etl/cdap-etl-core/src/test/java/co/cask/cdap/template/etl/common/TransformExecutorTest.java,TransformExecutorTest,testTransforms,#,42

Before Change


    );
    TransformExecutor<Integer, String> executor = new TransformExecutor<>(transforms, stageMetrics);

    List<String> results = Lists.newArrayList(executor.runOneIteration(1));
    Assert.assertTrue(results.isEmpty());
    Assert.assertEquals(3, mockMetrics.getCount("source.first.1.records.out"));
    Assert.assertEquals(0, mockMetrics.getCount("transform.second.2.records.out"));

After Change



    TransformExecutor<Integer, String> executor = new TransformExecutor<>(transforms);

    TransformResponse transformResponse = executor.runOneIteration(1);
    List<String> results = Lists.newArrayList(transformResponse.getEmittedRecords());
    Assert.assertTrue(results.isEmpty());
    Map<String, Collection> errorIteratorsMap = transformResponse.getMapTransformIdToErrorEmitter();